2ce2fda5b7f688f1c5fa9e10f7c8ff64ce99be12,gora-core/src/examples/java/org/apache/gora/examples/spark/SparkWordCount.java,SparkWordCount,wordCount,#DataStore#DataStore#,71

Before Change


    JavaPairRDD<String, Long> reducedGoraRdd = JavaPairRDD.fromJavaRDD(mappedGoraRdd).reduceByKey(redFunc);

    //Print output for debug purpose
    System.out.println("SparkWordCount debug purpose TokenDatum print starts:");
    Map<String, Long> tokenDatumMap = reducedGoraRdd.collectAsMap();
    for (String key : tokenDatumMap.keySet()) {
      System.out.println(key);
      System.out.println(tokenDatumMap.get(key));
    }
    System.out.println("SparkWordCount debug purpose TokenDatum print ends:");
    //

After Change


    Map<String, Long> tokenDatumMap = reducedGoraRdd.collectAsMap();
    for (String key : tokenDatumMap.keySet()) {
      log.info(key);
      log.info(tokenDatumMap.get(key).toString());
    }
    log.info("SparkWordCount debug purpose TokenDatum print ends:");
    //